package com.norma.netty.study.netty.disruptor.core;

import com.lmax.disruptor.WorkHandler;
import com.norma.netty.study.netty.disruptor.TransDataWrapper;
import lombok.Getter;
import lombok.Setter;

/**
 * @author zhangchaofeng
 * @date 2021/1/5
 * @description
 */
@Getter
@Setter
public abstract class MessageConsumer implements WorkHandler<TransDataWrapper> {

    protected String consumerId;

    public MessageConsumer(String consumerId) {
        this.consumerId = consumerId;
    }

}
